package com.agent.action.interfaces;

import com.agent.action.entity.DifyWorkFlowEntity;
import com.agent.action.param.FlowPauseParam;
import com.agent.action.param.PauseParam;
import reactor.core.publisher.Flux;

/**
 * Dify工作流调用接口
 */
public interface WorkFlowClient<T> {
    /**
     * 工作流的流式响应
     * @param data
     * @return
     */
    public Flux<String> stream(DifyWorkFlowEntity<T> data);

    /**
     * 工作流的流式暂停
     * @param flowpauseParam
     */
    public void pause(PauseParam flowpauseParam);
}
